import { getToken } from '@renderer/utils/auth';
import { ElNotification } from 'element-plus';
import { MessageVo } from '@renderer/enums/IMMessageDTO';
import {createIMage} from '@renderer/utils/ruoyi'
import { useIMStore } from '@renderer/store/modules/im';
// 初始化
export const initSSE = (url: any) => {
  if (import.meta.env.VITE_APP_SSE === 'false') {
    return;
  }

  url = url + '?Authorization=Bearer ' + getToken() + '&clientid=' + import.meta.env.VITE_APP_CLIENT_ID;
  const {
    data,
    error
  } = useEventSource(url, [], {
    autoReconnect: {
      retries: 10,
      delay: 3000,
      onFailed() {
        console.log('Failed to connect after 10 retries');
      }
    }
  });

  watch(error, () => {
    console.log('SSE connection error:', error.value);
    error.value = null;
  });

  watch(data, () => {
    if (!data.value) return;
    const message:MessageVo = JSON.parse(data.value);
    if (!message.ifRead && message.ifUpCount) {
      useIMStore().add(message.messageType);
    }
    if (message.ifHint) {
      ElNotification({
        title: message.messageTitle,
        dangerouslyUseHTMLString: true,
        message: createIMage(message),
      });
    }
    data.value = null;
  });
};
